package com.linsy.product.redis.mq.config;

import cn.hutool.core.util.StrUtil;

import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

/**
 * 配置文件
 */
public class KernelMqDataConfig {

    private KernelMqDataConfig(){
    }

    /**
     * 扫描出来的消费类
     */
    public static Set<Class<?>> classSet = null;

    /**
     * 全局定时任务
     */
    public static String cron = StrUtil.EMPTY;

    /**
     * 主题运行状态
     */
    public static final ConcurrentMap<String, Thread> TOPIC_RUN_STATE = new ConcurrentHashMap<>();
}
